package com.imooc.order.message;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * 
 * @author jack
 * @date 2019年1月19日
 */
public interface StreamClient {

	String INPUT = "myMessageInput";
	String OUTPUT = "myMessageOutput";
	
	String ORDER_RS_INPUT = "orderRsInput";
	String ORDER_RS_OUTPUT = "orderRsOutput";
	
	@Input(INPUT)
	SubscribableChannel input();
	
	@Output(OUTPUT)
	MessageChannel output();
	
	@Input(ORDER_RS_INPUT)
	SubscribableChannel orderRsInput();
	
	@Output(ORDER_RS_OUTPUT)
	MessageChannel orderRsOutput();
}
